package avicit.bdp.dcs.stream.dto;

/**
 * @金航数码科技有限责任公司
 * @作者：developer
 * @邮箱：developer@avic-digital.com
 * @创建时间： 2020-10-16
 * @类说明：KafkaJsonDto
 * @修改记录：
 * @注意事项：
 */
public class KafkaJsonDto {

    // kafka主题
    private String topics;

    // kafka分区
    private String kafkaPartitions;

    // 消息唯一标识
    private String msgId;

    // 消息格式，protobuf、json、avro、xml
    private String msgAgreement;

    // 消息模板标识
    private String msgTemplate;

    // Kafka Reader选择protobuf格式时，消息解析方式(跟具体厂商绑定)
    private String analysisMode;

    /**
     * Kafka Consumer Group Id，支持选定现有groupId、随机生成groupId
     */
    private String groupId;

    /**
     * Kafka消费者消费模式，包括earliest、latest、none三种。
     */
    private String autoOffestRest;

    public String getKafkaPartitions() {
        return kafkaPartitions;
    }

    public void setKafkaPartitions(String kafkaPartitions) {
        this.kafkaPartitions = kafkaPartitions;
    }

    public String getTopics() {
        return topics;
    }

    public void setTopics(String topics) {
        this.topics = topics;
    }

    public String getMsgId() {
        return msgId;
    }

    public void setMsgId(String msgId) {
        this.msgId = msgId;
    }

    public String getMsgTemplate() {
        return msgTemplate;
    }

    public void setMsgTemplate(String msgTemplate) {
        this.msgTemplate = msgTemplate;
    }

    public String getMsgAgreement() {
        return msgAgreement;
    }

    public void setMsgAgreement(String msgAgreement) {
        this.msgAgreement = msgAgreement;
    }

    public String getAnalysisMode() {
        return analysisMode;
    }

    public void setAnalysisMode(String analysisMode) {
        this.analysisMode = analysisMode;
    }

    public String getGroupId() {
        return groupId;
    }

    public void setGroupId(String groupId) {
        this.groupId = groupId;
    }

    public String getAutoOffestRest() {
        return autoOffestRest;
    }

    public void setAutoOffestRest(String autoOffestRest) {
        this.autoOffestRest = autoOffestRest;
    }

    @Override
    public String toString() {
        return "{" +
                "topics:'" + topics + '\'' +
                ", kafkaPartitions:'" + kafkaPartitions + '\'' +
                ", msgId:'" + msgId + '\'' +
                ", msgAgreement:'" + msgAgreement + '\'' +
                ", msgTemplate:'" + msgTemplate + '\'' +
                ", analysisMode:'" + analysisMode + '\'' +
                ", groupId:'" + groupId + '\'' +
                ", autoOffestRest:'" + autoOffestRest + '\'' +
                '}';
    }
}
